/*
 * reader.cpp
 *
 *  Created on: 22/07/2014
 *      Author: nicolas
 */

#include "../../ipc/Socket.h"
#include <string.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include "../../defines.h"
#include <iostream>

using namespace std;

int main(int argc, char **argv) {

	if (argc != 1) {
		perror("cantidad de args invalida");
		exit(1);
	}

	Socket sock;
	int puerto = 5555;
	MENSAJE_BROKER msg;
	msg.esReceptor = false; // la direccion de la comunicacion es broker -> cliente
	msg.id = 3;

	sock.connectTo("localhost", puerto);
	sock.send(&msg, sizeof(MENSAJE_BROKER));

	bool salir = false;

	while (!salir) {
		sock.recv(&msg, sizeof(MENSAJE_BROKER));
		cout << "Se recibio mensaje con respuesta: " << msg.valorLeido << endl;
		if (msg.tipo == TIPO_FINALIZAR)
			salir = true;
	}

	sock.closeSock();
}

